const api = require('./api')
// const fs = require('fs')
// const path = require('path')
const bodyParser = require('body-parser')
const express = require('express')
const cors = require('cors')
const app = express()
const http = require('http')
const WebSocket = require('ws')

app.use(cors())
// app.all("*",function(req,res,next){
//   //设置允许跨域的域名，*代表允许任意域名跨域
//   res.header("Access-Control-Allow-Origin","*");
//   //允许的header类型
//   res.header("Access-Control-Allow-Headers","content-type");
//   //跨域允许的请求方式 
//   res.header("Access-Control-Allow-Methods","DELETE,PUT,POST,GET,OPTIONS");
//   if (req.method.toLowerCase() == 'options')
//       res.send(200);  //让options尝试请求快速结束
//   else
//       next();
// })
app.use(bodyParser.json())
app.use(bodyParser.urlencoded({ extended: false }))
app.use(api)
// app.use(express.static(path.resolve(__dirname, '../dist')))
// app.get('*', function (req, res) {
//   const html = fs.readFileSync(path.resolve(__dirname, '../dist/index.html'), 'utf-8')
//   res.send(html)
// })
// const rs = fs.createReadStream('../static/logo.png')
// const ws = fs.createWriteStream('./a.png')
// rs.pipe(ws)
app.listen(8089)
console.log('success listen......')
const server = http.createServer(app)
const wss = new WebSocket.Server({ server })

wss.on('connection', (ws) => {
  console.log('链接成功！')
  ws.on('message', (data) => {
    console.log(data)
    wss.clients.forEach((client) => {
      client.send(data)
    })
  })
})
server.listen(8088)
